package com.kyrie.kafka;

import lombok.Data;

/***
 * 描述: kafka消费者conf
 *
 * @author wuxiang
 * @date 2020-04-24 13:29
 */
@Data
public class KafkaConsumerConf {

    // 消费组id
    private String groupId;

    // 自动位移提交
    private Boolean enableAutoCommit;

    // 自动位移提交间隔时间
    private Integer autoCommitInterval;

    // 消费组失效超时时间
    private Integer sessionTimeout;

    // 位移丢失和位移越界后的恢复起始位置
    private String autoOffsetReset;

    // 心跳时间
    private String heartbeatInterval;

    // 是否开启批量消息消费
    private Boolean enableBatch;

    // 批量消费消息最大数量
    private String maxPollRecords;
}
